4360e2b06c47128b318379a1e3726dbae3845080,src/test/java/io/confluent/connect/hdfs/avro/DataWriterAvroTest.java,DataWriterAvroTest,testProjectForward,#,461
Before Change
hdfsWriter.write(sinkRecords);
hdfsWriter.close();
path = new Path(FileUtils.committedFileName(url, topicsDir, DIRECTORY, TOPIC_PARTITION, 2L,
2L, extension, ZERO_PAD_FMT));
records = (ArrayList<Object>) schemaFileReader.readData(conf, path);
assertEquals(1, records.size());
After Change
assertEquals(avroData.fromConnectData(newSchema, newRecord), records.get(0));
path = new Path(FileUtils.committedFileName(url, topicsDir, DIRECTORY, TOPIC_PARTITION, 1L,
2L, extension, ZERO_PAD_FMT));
records = (ArrayList<Object>) schemaFileReader.readData(conf, path);
assertEquals(avroData.fromConnectData(schema, record), records.get(0));
assertEquals(avroData.fromConnectData(schema, record), records.get(1));